package org.ala.tiktools.rocketmq.annotations;

import org.ala.tiktools.rocketmq.Namespace;
import org.springframework.stereotype.Component;

import java.lang.annotation.*;


/**
 * @author ala
 * @date 2024-12-05 10:41
 */
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Component
public @interface ProducerService {

    /**
     *  namesrv
     *  <p> 若为NULL则使用公共配置
     */
    String namesrvAddrs() default Namespace.NULL;


    /**
     *  消费组
     *  <p> 如果不为NULL，Service类下的默认group
     */
    String group() default Namespace.DEFAULT_GROUP;
    /**
     *  topic
     *  <p> 如果不为NULL，Service类下的默认topic
     */
    String topic() default Namespace.NULL;


    /**
     *  默认队列数
     *  <p> 只在初始化时有效，有可能后期被控制台修改
     */
    int defaultQueueNum() default Namespace.INF;

}
